package com.example.demo.mq;

import com.example.demo.constant.Constant;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Component;


/**
 * 导出mq接收处理
 *
 * @author xiaobeibei@gogpay.cn
 * @date 2023-12-08 15:07
 */
@Component
@RabbitListener(queues = Constant.EXPORT_QUEUE)
public class ExportReceiver {

    private static final Logger LOGGER= LoggerFactory.getLogger(ExportReceiver.class);

    @RabbitHandler
    public void exportQueueHandler(@Payload String message){
        LOGGER.info("接收异步导出数据通知，{}",message);

    }
}
